package io.kimmking.kmq.core;

import lombok.Data;

import java.util.HashMap;

@Data
public class KmqMessage {

    private String topic;

    private HashMap<String, Object> headers;

    private Object body;

    public KmqMessage(String topic, HashMap<String, Object> headers, Object body) {
        this.topic = topic;
        this.headers = headers;
        this.body = body;
    }

    public KmqMessage(HashMap<String, Object> headers, Object body) {
        this.headers = headers;
        this.body = body;
    }

    public KmqMessage() {
    }
}
